#if !defined(_APP_MQTT)
#define _APP_MQTT

#define mqtt_broker_url "ws://192.168.44.51:1883"
#define mqtt_client_id "06cf5e3c-039f-11f0-ae02-2773a39b1571"

#define mqtt_topic_send "gateway_to_web"
#define mqtt_topic_receive "web_to_gateway"
#define mqtt_qos_level 1

/**
 * @brief  初始化mqtt
 * 
 * 
 *  1    创建一个客户端实例  （init）
    2    设置事件的回调函数   1  失联事件  2  消息到达事件 3 消息发送成功事件   （init）
    3    客户端正式连接服务端  （init）
    4    客户端订阅主题    （init）
 */
 int app_mqtt_init();


 /**
  * @brief  发送消息
  * @param  要发送的数据 
  * @param  要发送的数据长度
  * 
  */
int app_mqtt_send(char *data,int len);



/**
 * @brief  由外部向消息队列模块中注册回调函数
 * @param  回调函数
 * @return  0  成功  -1 失败
 */
int app_mqtt_register_callback(int (*callback)(char *data,int len));


/**
 * @brief 销毁消息队列的相关资源
 *  1  关闭连接
 *  2  销毁消息队列句柄
 */
void app_mqtt_destroy();


#endif // _APP_MQTT
